3b708f9989274cbe9e0e2a5fda6f1d0a3d96ebee,examples/hadoop_cql3_word_count/src/WordCountCounters.java,WordCountCounters,run,#String[]#,112

Before Change


        job.setReducerClass(ReducerToFilesystem.class);
        job.setOutputKeyClass(Text.class);
        job.setOutputValueClass(LongWritable.class);
        FileOutputFormat.setOutputPath(job, new Path(OUTPUT_PATH_PREFIX));

        job.setInputFormatClass(CqlPagingInputFormat.class);

After Change


        {
            job.setMapperClass(SumNativeMapper.class);
            job.setInputFormatClass(CqlInputFormat.class);
            CqlConfigHelper.setInputCql(job.getConfiguration(), "select * from " + WordCount.OUTPUT_COLUMN_FAMILY + " where token(word) > ? and token(word) <= ? allow filtering");
        }
        else
        {
            job.setMapperClass(SumMapper.class);
            job.setInputFormatClass(CqlPagingInputFormat.class);
            ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160");
        }

        job.setOutputKeyClass(Text.class);
        job.setOutputValueClass(LongWritable.class);
        FileOutputFormat.setOutputPath(job, new Path(OUTPUT_PATH_PREFIX));
        job.waitForCompletion(true);
        return 0;
    }